package org.apache.flink.runtime.client;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.api.common.ConsumingStatus;

/** A simple message that holds the state of a resource consuming. */
/**
 * @类名: ConsumerStatusMessage
 * @说明: 资源消费者状态消息
 *
 * @author   leehom
 * @Date	 2024年2月22日 下午3:40:58
 * 修改记录：
 *
 * @see 	 
 */
public class ConsumingStatusMessage implements java.io.Serializable {

    private final ConsumerID consumerId;

    private final String consumerName;

    private final ConsumingStatus consumingState;

    private final long startTime;

    public ConsumingStatusMessage(ConsumerID consumerId, String jobName, ConsumingStatus jobState, long startTime) {
        this.consumerId = consumerId;
        this.consumerName = jobName;
        this.consumingState = jobState;
        this.startTime = startTime;
    }

    public ConsumerID getJobId() {
        return consumerId;
    }

    public String getJobName() {
        return consumerName;
    }

    public ConsumingStatus getJobState() {
        return consumingState;
    }

    public long getStartTime() {
        return startTime;
    }
}
